exports.sendSystemMessage = function (req, res) {

    //获取参数信息
    var bodyParams = req.routeInfo.bodyParams;

    //返回结果
    var resultData = {};

    //查询接收用户的主键id及基本信息
    var  to_id    = ""
    var  todata   = {}

    //查询接收用户的命名空间id
    var n_id = ""

    //任务流创建
    async.waterfall([

        //查询命名空间id
        //获取接收人的基本信息
        //发送系统消息
        (cb)=> {
            db.field('n_id').where({
                "n_appid" : bodyParams.severAppId
            }).select("socket_namespace",(rs) => {
                //不存在
                if(rs.length == 0){
                    return RES.errorResponse(res,"此appId不存在");
                }
                n_id = rs[0].n_id
                cb();
            })

        },

        (cb) => {
            if(bodyParams.toUserIds == 0){
                db.field('u_username').where({
                    "u_is_delete" : 0
                }).select("socket_user",(rs)=>{
                    if(rs.length == 0){
                        return RES.errorResponse(res,"不存在此用户");
                    }
                    todata.usernames = rs
                    cb()
                })
            }else{
                todata.usernames = bodyParams.toUserIds
            }
        },
        (cb) => {
            var senddata = {}
            senddata.messageType = 'systemMessage'//发送系统消息
            senddata.type        = '1'//群销毁或新建消息
            var task = [];

            todata.usernames.forEach(function (item,i) {
                //创建每一个插入任务
                task.push(function (cb) {
                    socketObj._privateChat(senddata,item.u_username,(isTrue) => {
                        cb()
                    })
                });

            });
            async.waterfall(task,cb());
        }

    ],()=> {

        //返回最终拼接结果
        RES.successResponse(res,resultData);

    });
    
}